package com.tdxy.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

/**
 * JDBC的测试类
 */
public class JdbcMainStatement {
    // jdbc 协议 是java mysql 的连接数据库, 实现数据传输的协议。
    // 协议头 : jdbc:mysql://
    // local : 访问数据库的IP地址 127.0.0.1  或都是 localhost
    // port  : 访问数据库的端口号 默认端口是 3306 本机是3309
    // 直接使用某一个库 , 只对表进行相关操作 use db_tdxy ;
    public static final String URL = "jdbc:mysql://127.0.0.1:3309/db_tdxy";
    public static final String USER = "root";
    public static final String PWD = "root";    // 压缩包mysql数据库密码应该是 root@123

    public static void main(String[] args) throws Exception {
        // 1.通过反射加载驱动类
        // 通过参数给定的字符串找到指定的类, 加载到程序当中
        Class.forName("com.mysql.cj.jdbc.Driver");
        Connection conn = DriverManager.getConnection(URL, USER, PWD);
        System.out.println("conn = " + conn);
        // 2. 声明查询数据库的语句
        String user = "admin";
        String password = "a' or '1 =1";
        String sql = "select * from tb_user " +
                "where name ='"+user+"' and password = '"+password+"';";
        // 3. 创建Statement对象
        Statement stat = conn.createStatement();    // 不允许使用。
        // 4. 执行sql语句
        ResultSet res = stat.executeQuery(sql);

        while (res.next()){
            System.out.println("res.getObject(1) = " + res.getObject(1));
            System.out.println("res.getObject(2) = " + res.getObject(2));
            System.out.println("res.getObject(3) = " + res.getObject(3));
        }


    }
}
